feature/work/com.shifthackz.aisdv1.work/[ios]BackgroundTaskManagerImpl

BackgroundTaskManagerImpl

internal class BackgroundTaskManagerImpl(val backgroundWorkObserver: BackgroundWorkObserver, val textToImageUseCase: TextToImageUseCase, val imageToImageUseCase: ImageToImageUseCase, val interruptGenerationUseCase: InterruptGenerationUseCase, val observeHordeProcessStatusUseCase: ObserveHordeProcessStatusUseCase, val observeLocalDiffusionProcessStatusUseCase: ObserveLocalDiffusionProcessStatusUseCase, val observeCoreMlProcessStatusUseCase: ObserveCoreMlProcessStatusUseCase, val observeBonsaiProcessStatusUseCase: ObserveBonsaiProcessStatusUseCase, val preferenceManager: PreferenceManager) : BackgroundTaskManager(source)

Implements BackgroundTaskManager behavior for iOS background generation.

Author

Dmitriy Moroz

Constructors

BackgroundTaskManagerImpl

constructor(backgroundWorkObserver: BackgroundWorkObserver, textToImageUseCase: TextToImageUseCase, imageToImageUseCase: ImageToImageUseCase, interruptGenerationUseCase: InterruptGenerationUseCase, observeHordeProcessStatusUseCase: ObserveHordeProcessStatusUseCase, observeLocalDiffusionProcessStatusUseCase: ObserveLocalDiffusionProcessStatusUseCase, observeCoreMlProcessStatusUseCase: ObserveCoreMlProcessStatusUseCase, observeBonsaiProcessStatusUseCase: ObserveBonsaiProcessStatusUseCase, preferenceManager: PreferenceManager)

Properties

activeJob

private var activeJob: Job?

backgroundWorkObserver

private val backgroundWorkObserver: BackgroundWorkObserver

coroutineScope

private val coroutineScope: CoroutineScope

imageToImageUseCase

private val imageToImageUseCase: ImageToImageUseCase

interruptGenerationUseCase

private val interruptGenerationUseCase: InterruptGenerationUseCase

lastImageToImagePayload

private var lastImageToImagePayload: ImageToImagePayload?

lastTextToImagePayload

private var lastTextToImagePayload: TextToImagePayload?

observeBonsaiProcessStatusUseCase

private val observeBonsaiProcessStatusUseCase: ObserveBonsaiProcessStatusUseCase

observeCoreMlProcessStatusUseCase

private val observeCoreMlProcessStatusUseCase: ObserveCoreMlProcessStatusUseCase

observeHordeProcessStatusUseCase

private val observeHordeProcessStatusUseCase: ObserveHordeProcessStatusUseCase

observeLocalDiffusionProcessStatusUseCase

private val observeLocalDiffusionProcessStatusUseCase: ObserveLocalDiffusionProcessStatusUseCase

preferenceManager

private val preferenceManager: PreferenceManager

statusScope

private val statusScope: CoroutineScope

textToImageUseCase

private val textToImageUseCase: TextToImageUseCase

Functions

cancelAll

open override fun cancelAll(): Result<Unit>

Executes the cancelAll step in the SDAI background work feature layer.

clearStatusSubscriptions

private fun clearStatusSubscriptions()

isActiveJob

private fun isActiveJob(job: Job): Boolean

listenBonsaiStatus

private fun listenBonsaiStatus()

listenCoreMlStatus

private fun listenCoreMlStatus()

listenHordeStatus

private fun listenHordeStatus()

listenLocalDiffusionStatus

private fun listenLocalDiffusionStatus()

listenSourceStatus

private fun listenSourceStatus()

postRunningMessage

private fun postRunningMessage()

postStepMessage

private fun postStepMessage(current: Int, total: Int)

retryLastImageToImageTask

open override fun retryLastImageToImageTask(): Result<Unit>

Executes the retryLastImageToImageTask step in the SDAI background work feature layer.

retryLastTextToImageTask

open override fun retryLastTextToImageTask(): Result<Unit>

Executes the retryLastTextToImageTask step in the SDAI background work feature layer.

runGenerationTask

private fun runGenerationTask(block: suspend () -> List<AiGenerationResult>)

scheduleImageToImageTask

open override fun scheduleImageToImageTask(payload: ImageToImagePayload)

Executes the scheduleImageToImageTask step in the SDAI background work feature layer.

scheduleTextToImageTask

open override fun scheduleTextToImageTask(payload: TextToImagePayload)

Executes the scheduleTextToImageTask step in the SDAI background work feature layer.